package com.ai.networking.websocket.service.comm;

import com.ai.networking.websocket.service.WebSocket;

import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CopyOnWriteArraySet;

public class CommonWebSocket {

    /**
     * webSocket 初始列表
     */
    public static CopyOnWriteArraySet<WebSocket> WS_SOCKET_SET = new CopyOnWriteArraySet<>();

    /**
     * 直播列表
     */
    public static ConcurrentHashMap<Integer, CopyOnWriteArraySet<WebSocket>> WS_LIVE_MAP = new ConcurrentHashMap<>();
}
